Little Angular programmer's library

Оператор shareReplay

Оператор shareReplay в RxJS используется для создания разделяемого и повторяемого Observable. Он выполняет две основные функции: совместное использование значений между подписчиками и повторное выполнение источника данных для новых подписчиков. Это полезно, когда требуется получить последние значения из источника данных, даже если подписчик подписывается позднее.

Давайте рассмотрим шаги и примеры кода для лучшего понимания оператора shareReplay:

Шаг 1: Импорт необходимых функций и операторов из библиотеки RxJS:

import { of } from 'rxjs';
import { tap, map, shareReplay } from 'rxjs/operators';

Шаг 2: Создание источника данных (Observable) и применение оператора shareReplay:

const source$ = of(1, 2, 3).pipe(
  tap((value) => console.log('Исходное значение:', value)),
  map((value) => value * 2),
  shareReplay(1)
);

В этом примере мы создаем источник данных source$, который испускает значения 1, 2, 3. Затем мы применяем операторы tap и map для преобразования значений и отладочного вывода. Наконец, мы применяем оператор shareReplay(1), который делает source$ разделяемым и повторяемым, сохраняя последнее значение и повторно выполняя источник данных для новых подписчиков.

Шаг 3: Подписка на разделяемый и повторяемый Observable:

source$.subscribe((value) => console.log('Подписка 1:', value));

source$.subscribe((value) => console.log('Подписка 2:', value));

В этом примере мы подписываемся на source$ два раза, и каждая подписка выводит полученные значения в консоль.

Объяснение: Оператор shareReplay создает разделяемый и повторяемый Observable, который предоставляет одну и ту же последовательность значений для всех подписчиков и сохраняет последнее значение. Когда первый подписчик подписывается на разделяемый Observable, он начинает выполнение источника данных и получает все значения. Если новый подписчик подписывается позже, он сразу получает последнее сохраненное значение источника данных и затем продолжает получать последующие значения. Это позволяет новым подписчикам получать последние значения даже после того, как эти значения уже были испущены.

Оператор shareReplay принимает аргумент, который указывает количество последних значений, которые нужно сохранять для новых подписчиков. В нашем примере мы передаем аргумент 1, что означает, что будет сохраняться только последнее значение.